import express from 'express';
const router = express.Router();
router.post('/test', (req, res, next) => {
  // 给客户端返回一个文件流
  res.setHeader('Content-Type','text/event-stream');
  res.setHeader('Cache-Control','no-cache');
  res.setHeader('Connection','keep-alive');

  let startTime = Date.now();
  const sendEvent = () => {
    // 检查是否已经发送了10秒
    if (Date.now() - startTime >= 10000) {
      res.write('event: close\ndata: {}\n\n'); // 发送一个特殊事件通知客户端关闭
      res.end(); // 关闭连接
      return;
    }

    const data = { message: 'Hello World', timestamp: new Date() };
    res.write(`data: ${JSON.stringify(data)}\n\n`);

    // 每隔2秒发送一次消息
    setTimeout(sendEvent, 2000);
  };
  sendEvent();
})

module.exports = router;
